bfcb69a2a6a4f82bdec21c8811ac72460a0b5611,hazelcast/src/main/java/com/hazelcast/mapreduce/impl/task/JobSupervisor.java,JobSupervisor,cancel,#,211
Before Change
public void cancel() {
String jobId = getConfiguration().getJobId();
jobTracker.unregisterTrackableJob(jobId);
jobTracker.unregisterMapCombineTask(jobId);
jobTracker.unregisterReducerTask(jobId);
mapReduceService.destroyJobSupervisor(this);
}
After Change
public void cancel() {
String jobId = getConfiguration().getJobId();
jobTracker.unregisterTrackableJob(jobId);
MapCombineTask mapCombineTask = jobTracker.unregisterMapCombineTask(jobId);
if (mapCombineTask != null) {
mapCombineTask.cancel();
}
ReducerTask reducerTask = jobTracker.unregisterReducerTask(jobId);
if (reducerTask != null) {